package com.yangcangclub.mq.service;


/**
 *
 * @author  flyger
 * @date    2016/7/21
 * @desc    MQ服务接口
 */
public interface MQService {

    /**
     * 添加MQTopic
     * @param partition
     * @param topic
     * @param server
     * @return
     */
    public  int addMQTopic(int partition,String topic, String server);



}
